package main

import (
	"fmt"
	"strconv"
	"time"
	"topic/mq"
)

func main() {
	aswOne := mq.NewRabbitMQTopic("asw2", "asw.topic.one")
	aswTwo := mq.NewRabbitMQTopic("asw2", "asw.topic.two")
	for i := 0; i <= 100; i++ {
		aswOne.PublishTopic("Hello asw topic one!" + strconv.Itoa(i))
		aswTwo.PublishTopic("Hello asw topic two!" + strconv.Itoa(i))
		time.Sleep(1 * time.Second)
		fmt.Println(i)
	}
}
